package com.ojoin.trade.supplyloan_core.utils.catchdata;

import java.util.concurrent.CountDownLatch;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MymonitoringThread implements Runnable {
    private String jobNum ;
	private static final Logger logger = LoggerFactory
			.getLogger(MymonitoringThread.class);
	private CountDownLatch downLatch;

	public MymonitoringThread(CountDownLatch downLatch,String jobNum) {
		this.downLatch = downLatch;
		this.jobNum = jobNum;
	} 
  
	@Override
	public void run() { 
		try {
			logger.info("jobNum-->"+jobNum+"监控抓取任务线程已经开启");
			this.downLatch.await();
			//Map<Integer,TbSlStattaskRunresult> map = SLDataCatchBaseServiceImpl.map;
			 
		} catch (InterruptedException e) {
		}finally{
			logger.info("jobNum-->"+jobNum+"监控抓取任务线程已完成");
		}
	
	}

}
